35da6a50868b33cca0bbcaf351e5770f6d821ab4,src/test/java/com/continuuity/runtime/FlowTest.java,FlowTest,testCountRandomApp,#,163
Before Change
@Test
public void testCountRandomApp() throws Exception {
final CConfiguration configuration = CConfiguration.create();
configuration.set(Constants.CFG_APP_FABRIC_TEMP_DIR, System.getProperty("java.io.tmpdir") + "/app/temp");
configuration.set(Constants.CFG_APP_FABRIC_OUTPUT_DIR, System.getProperty("java.io.tmpdir")
+ "/app/archive" + UUID.randomUUID());
Injector injector = Guice.createInjector(new DataFabricModules().getInMemoryModules(),
new BigMamaModule(configuration));
LocalLocationFactory lf = new LocalLocationFactory();
Location deployedJar = lf.create(
JarFinder.getJar(TestCountRandomApp.class, TestHelper.getManifestWithMainClass(TestCountRandomApp.class))
);
deployedJar.deleteOnExit();
ListenableFuture<?> p = TestHelper.getLocalManager(configuration).deploy(DefaultId.ACCOUNT, deployedJar);
final ApplicationWithPrograms app = (ApplicationWithPrograms)p.get();
ProgramController controller = null;
for (final Program program : app.getPrograms()) {
if (program.getProcessorType() == Type.FLOW) {
After Change
@Test
public void testCountRandomApp() throws Exception {
TestHelper.getInjector().getInstance(DiscoveryService.class).startAndWait();
final ApplicationWithPrograms app = TestHelper.deployApplicationWithManager(TestCountRandomApp.class);
ProgramController controller = null;
for (final Program program : app.getPrograms()) {
if (program.getProcessorType() == Type.FLOW) {
ProgramRunner runner = TestHelper.getInjector().getInstance(FlowProgramRunner.class);
controller = runner.run(program, new ProgramOptions() {
@Override
public String getName() {